//package org.example.stream1;
//
//import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.data.redis.connection.stream.MapRecord;
//import org.springframework.data.redis.stream.StreamListener;
//import org.springframework.stereotype.Service;
//
//@Slf4j
//@Service
////@RequiredArgsConstructor
//public class MyStreamListener implements StreamListener<String, MapRecord<String, String, String>> {
//
//    @Override
//    public void onMessage(MapRecord<String, String, String> message) {
//        log.info("Receive Stream[{}], message[{}]", message.getStream(), message);
//    }
//
//}
